02e5c3cff91f0b2044c9c7c7e7e57017de5f49b8,cdap-hbase-compat-0.98/src/main/java/co/cask/cdap/data2/transaction/queue/coprocessor/hbase98/HBaseQueueRegionObserver.java,HBaseQueueRegionObserver,start,#CoprocessorEnvironment#,78

Before Change


      appName = HBaseQueueAdmin.getApplicationName(hTableName);
      flowName = HBaseQueueAdmin.getFlowName(hTableName);

      conf = env.getConfiguration();
      String hbaseNamespacePrefix = nameConverter.getNamespacePrefix(tableDesc);
      TableId queueConfigTableId = HBaseQueueAdmin.getConfigTableId(namespaceId);
      final String sysConfigTablePrefix = nameConverter.getSysConfigTablePrefix(tableDesc);
      txStateCache = new DefaultTransactionStateCacheSupplier(sysConfigTablePrefix, conf).get();
      txSnapshotSupplier = new Supplier<TransactionSnapshot>() {
        @Override
        public TransactionSnapshot get() {
          return txStateCache.getLatestState();
        }
      };
      configTableNameBytes = nameConverter.toTableName(hbaseNamespacePrefix, queueConfigTableId).getName();
      cConfReader = new CConfigurationReader(conf, sysConfigTablePrefix);
      configCache = ConsumerConfigCache.getInstance(conf, configTableNameBytes, cConfReader, txSnapshotSupplier);
    }
  }

After Change


      appName = HBaseQueueAdmin.getApplicationName(hTableName);
      flowName = HBaseQueueAdmin.getFlowName(hTableName);

      Configuration conf = env.getConfiguration();
      String hbaseNamespacePrefix = nameConverter.getNamespacePrefix(tableDesc);
      TableId queueConfigTableId = HBaseQueueAdmin.getConfigTableId(namespaceId);
      final String sysConfigTablePrefix = nameConverter.getSysConfigTablePrefix(tableDesc);
      txStateCache = new DefaultTransactionStateCacheSupplier(sysConfigTablePrefix, conf).get();
      txSnapshotSupplier = new Supplier<TransactionSnapshot>() {
        @Override
        public TransactionSnapshot get() {
          return txStateCache.getLatestState();
        }
      };
      configTableName = nameConverter.toTableName(hbaseNamespacePrefix, queueConfigTableId);
      cConfReader = new CConfigurationReader(conf, sysConfigTablePrefix);
      configCache = createConfigCache(env);
    }
  }